Spring Boot异步调用@Async

使用背景

在日常开发的项目中，当访问其他人的接口较慢或者做耗时任务时，

不想程序一直卡在耗时任务上，想程序能够并行执行，

我们可以使用多线程来并行的处理任务，也可以使用spring提供的异步处理方式@Async。

异步处理方式

调用之后，不返回任何数据。(这个文档)

调用之后，返回数据，通过Future来获取返回数据

@Async配置

@Configuration
@Async
public class AsyncTaskConfig implements AsyncConfigurer {

    // ThredPoolTaskExcutor的处理流程
    // 当池子大小小于corePoolSize，就新建线程，并处理请求
    // 当池子大小等于corePoolSize，把请求放入workQueue中，池子里的空闲线程就去workQueue中取任务并处理
    // 当workQueue放不下任务时，就新建线程入池，并处理请求，如果池子大小撑到了maximumPoolSize，就用RejectedExecutionHandler来做拒绝处理
    // 当池子的线程数大于corePoolSize时，多余的线程会等待keepAliveTime长时间，如果无请求可处理就自行销毁
    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
        taskExecutor.setCorePoolSize(10);// 最小线程数
        taskExecutor.setMaxPoolSize(100);// 最大线程数
        taskExecutor.setQueueCapacity(25);// 等待队列
        taskExecutor.setKeepAliveSeconds(3000);
        taskExecutor.initialize();
        return taskExecutor;
    }

    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return null;
    }
}

启用@Async配置

为了让@Async注解能够生效，还需要在Spring Boot的主程序中配置@EnableAsync

@SpringBootApplication
@EnableFeignClients//启用FeignClients
@MapperScan(basePackages = "com.iguard.scheduler.dataobject.mapper")//加载mapper
@EnableAsync//启用Async
@EnableScheduling
public class SchedulerApplication {

	public static void main(String[] args) {
		SpringApplication.run(SchedulerApplication.class, args);
	}
}

在需要异步处理的方法上添加注解@Async

@Async
    public void asyncHandleData(){
    }